//package com.hmall.pay.mq;
//
//import com.rabbitmq.client.Channel;
//import org.springframework.amqp.core.Message;
//import org.springframework.amqp.rabbit.annotation.*;
//import org.springframework.stereotype.Component;
//
//
//
//
//@Component
//public class RabbitMQConfig {
//    /**
//     * 监听消息，绑定队列设置队列过期时间
//     */
//    @RabbitListener(bindings = @QueueBinding(
//            exchange = @Exchange(value = "xkp_topic_exchange",type = "topic"),
//            value = @Queue(
//                    value = "xkp_queue",
//                    durable = "true",
//                    arguments = @Argument( // 设置队列参数
//                            name="x-message-ttl", // 设置队列过期时间
//                            type = "java.lang.Integer",
//                            value = "20000")),
//            key = "xkp.#"
//    ))
//    public void handlerMessage(Message message, Channel channel)throws Exception {
//        long deliveryTag = message.getMessageProperties().getDeliveryTag();
//        // 1. 转换消息
//        System.out.println("消息内容: " + new String(message.getBody()));
//        // 2. 手工签收
//        channel.basicAck(deliveryTag,true);
//    }
//}